const mysql = require('mysql');

function query(sql) {
    // 创建 mysql 连接，填写连接配置
    const con = mysql.createConnection({
        host: 'localhost',
        port: 3306,
        user: 'root',
        password: 'root',
        database: 'base',
        debug: ['ComQueryPacket'], // 'RowDataPacket'
    });

    // 返回一个 promise 然后就可以使用 await
    return new Promise((resolve, reject) => {
        // 发送 SQL 语句到 MySQL 服务器执行
        con.query(sql, (error, data) => {
            if (error) reject(error);
            else resolve(data);
        });

        // 关闭连接
        con.end();
    });
}

module.exports = query;
